welo git mirrors - /page/commit.mu

Micron Document

welo git mirrors

Node / public / rns-proxy / commits / 6e4ce54

Commit 6e4ce5424e418b0a7dfd31b66f25494fda92ca46

🗀 Browse tree at this commit

Parents : b7be9c8

Author : welo | main nixos computer <empty@empty.com>

Date : 2026-07-08T09:20:07+01:00

debug printint!

Changes

4 files changed, 5 insertions(+), 2 deletions(-)

M src/client.rs +3 -1

M src/frame.rs -1

M src/relay.rs +1

M src/server.rs +1

Diff

diff --git a/src/client.rs b/src/client.rs

index abde18c..a1331cb 100644

--- a/src/client.rs

+++ b/src/client.rs

@@ -394,6 +394,8 @@ async fn handle_tcp_connect(

) -> Option<TcpStream> {

// info!("udp test data: {:?}, {:?}",cmd, target_addr);

+ let (host, port) = target_addr.clone().into_string_and_port();

+ info!("[{}] -> {}:{} tcp", sid, host, port);

let connect_result = connect_tcp_server_side(sid,mux.clone(), session_rx, target_addr).await;

@@ -443,7 +445,7 @@ pub async fn udp_bind_connect(

{

let (host, port) = target_addr.into_string_and_port();

- info!("[{}] -> {}:{}", sid, host, port);

+ info!("[{}] -> {}:{} udp", sid, host, port);

// Send CONNECT frame through RNS

let connect_payload = encode_connect_payload(&host, port, true);

diff --git a/src/frame.rs b/src/frame.rs

index 967d8ba..5770955 100644

--- a/src/frame.rs

+++ b/src/frame.rs

@@ -154,6 +154,5 @@ pub fn decode_connect_payload(data: &[u8]) -> Option<(String, u16, bool)> {

let host = String::from_utf8(data[1..1 + n].to_vec()).ok()?;

let port = u16::from_be_bytes([data[1 + n], data[2 + n]]);

let udp = if (data[n + 3] & 0b10000000) == 0 {false} else { true };

- info!("{} {:?}", udp, data[n + 3]);

Some((host, port, udp))

}

diff --git a/src/relay.rs b/src/relay.rs

index 52c4bd0..67aff9f 100644

--- a/src/relay.rs

+++ b/src/relay.rs

@@ -52,6 +52,7 @@ pub async fn relay_bidirectional_tcp(

while let Some(frame) = session_rx.recv().await {

match frame.frame_type {

FrameType::Data => {

+ info!("{:?}", &frame.payload);

if let Err(e) = tcp_write.write_all(&frame.payload).await {

warn!("[{}] TCP write error: {}", sid, e);

break;

diff --git a/src/server.rs b/src/server.rs

index 4652071..6dabb3e 100644

--- a/src/server.rs

+++ b/src/server.rs

@@ -194,6 +194,7 @@ pub async fn run_server(identity_path: Option<&str>, filter_config: FilterConfig

}

FrameType::Data | FrameType::Close => {

+ info!("{:?}", frame);

mux.dispatch(frame);

}

_ => {}

Served by rngit 1.4.2 - Generated in 0.03s